package java811.java3;

import java811.java2.Employee;
import java811.java2.Employee;
import java811.java2.EmployeeData;
import org.junit.Test;

import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * 测试Stream的终止操作
 */
public class StreamAPITest2 {

    //1-匹配与查找
    @Test
    public void test1(){
        List<Employee> employees = EmployeeData.getEmployees();

        // allMatch(Predicate p)——检查是否匹配所有元素。
        // 练习：是否所有的员工的年龄都大于18    =>every
        boolean allMatch = employees.stream().allMatch(e -> e.getAge() > 18);
        System.out.println(allMatch);

        // anyMatch(Predicate p)—— 检查是否至少匹配一个元素。 =>some
        // 练习：是否存在员工的工资大于 10000
        boolean anyMatch = employees.stream().anyMatch(e -> e.getSalary() > 10000);
        System.out.println(anyMatch);

        // noneMatch(Predicate p) —— 检查是否没有匹配的元素。 全部都不符合才会返回true
        // 练习：是否存在员工姓“雷”
        boolean noneMatch = employees.stream().noneMatch(e -> e.getName().startsWith("雷"));
        System.out.println(noneMatch);

        // findFirst——返回第一个元素
        Optional<Employee> employee = employees.stream().findFirst();
        System.out.println(employee);
        // findAny——返回当前流中的任意1个符合条件的元素  将最终结果封装到了Optional对象里面
        Optional<Employee> employee1 = employees.parallelStream().filter(e->e.getAge()>18).findAny();// 有可能找不到 存在null 指针异常的可能, 所以被Optional打包一下
        employee1.ifPresent((e)-> System.out.println(e.getName()));//Consumer  // 有则执行，无也不会报空指针异常
//        System.out.println(employee1);
        Optional<Employee> first = employees.stream().sorted((e1, e2) -> e1.getAge() - e2.getAge()).findFirst();
        first.ifPresent((e)-> System.out.println(e.getName()));// 获取年纪最小的 人的名字  有则执行，无也不会报空指针异常

    }

    @Test
    public void test2(){
        List<Employee> employees = EmployeeData.getEmployees();
        // count——返回流中元素的总个数
        long count = employees.stream().filter(e -> e.getSalary() > 5000).count();
        System.out.println(count);
        // max(Comparator c)——返回流中最大值
        // 练习：返回最高的工资：
        Stream<Double> salaryStream = employees.stream().map(e -> e.getSalary());
        Optional<Double> maxSalary = salaryStream.max(Double::compare);
        // Optional<Double> max = employees.stream().map(e -> e.getSalary()).max(Double::compare);
        // Optional<Double> min = employees.stream().map(e -> e.getSalary()).min(Double::compare);

        System.out.println(maxSalary);
        // min(Comparator c)——返回流中最小值
        // 练习：返回最低工资的  员工
        Optional<Employee> employee = employees.stream().min((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
        Optional<Employee> employee2 = employees.stream().max((e1, e2) -> Double.compare(e1.getSalary(), e2.getSalary()));
        System.out.println(employee);
        System.out.println(employee2);
        System.out.println();


        //  forEach(Consumer c)——内部迭代
        employees.stream().forEach(System.out::println);

        //使用集合的遍历操作
        employees.forEach(System.out::println);
    }

    //2-归约 reduce 的 使用
    @Test
    public void test3(){
//        reduce(T identity, BinaryOperator)——可以将流中元素反复结合起来，得到一个值。返回 T
//        练习1：计算1-10的自然数的和  // 两个参数 返回的参数 可直接定下来
        List<Integer> list = Arrays.asList(1,2,3,4,5,6,7,8,9,10);
        Integer sum = list.stream().reduce(0, Integer::sum);
//        Integer sum = list.stream().reduce(0,(d1,d2) -> d1 + d2);
        System.out.println(sum);


//        reduce(BinaryOperator) ——可以将流中元素反复结合起来，得到一个值。返回 Optional<T>
//        练习2：计算公司所有员工工资的总和    单个参数  返回optional 对象
        List<Employee> employees = EmployeeData.getEmployees();
        Stream<Double> salaryStream = employees.stream().map(Employee::getSalary);
//        Optional<Double> sumMoney = salaryStream.reduce(Double::sum);

        Optional<Double> sumMoney = salaryStream.reduce((d1,d2) -> d1 + d2); // 单个参数  返回optional 对象
        //  Optional<Double> sumMoney2 = Optional.ofNullable(salaryStream.reduce((double) 0, (d1, d2) -> d1 + d2));  // 初值 (double) 0,
        //  Optional<Double> sumMoney2 = salaryStream.reduce(Double::sum);
//        sumMoney.ifPresent(s-> System.out.println(s)); // 也可以这样写
        System.out.println(sumMoney.get());


        // reduce 三个参数的情况
    }

    //3-收集 => 转成List
    @Test
    public void test4(){
//        collect(Collector c)——将流转换为其他形式。接收一个 Collector接口的实现，用于给Stream中元素做汇总的方法
//        练习1：查找工资大于6000的员工，结果返回为一个List或Set

        List<Employee> employees = EmployeeData.getEmployees();
        List<Employee> employeeList = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toList());

        employeeList.forEach(System.out::println);
        System.out.println();
        Set<Employee> employeeSet = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toSet());

        employeeSet.forEach(System.out::println);




    }
}
